package com.bigdata.spark.core.test

/**
 * @author Gerry chan
 * @version 1.0
 * P23: https://www.bilibili.com/video/BV11A411L7CK?p=23
 * Task 相当于分布式中的数据结构 RDD
 */
class Task extends  Serializable {
  //数据
  val datas = List(1,2,3,4)
  //定义匿名函数
  val logic = (num:Int) => {num * 2}

  // 也可以是下面的写法
  //val logic2:(Int)=>Int = _ *2
  //定义计算任务
  def compute():Any = {
    datas.map(logic)
  }
}
